package main

import (
	"test/job"
	"time"
)

func main() {
	//初始化worker池
	job.InitWorkerPool()

	go job.Dispatch()

	for i := 0; i < 10; i++ {
		job.Schedule(i)
	}

	time.Sleep(5 * time.Second)

}
